//package com.hx.dc.controllor;
//
//import java.io.IOException;
//import java.util.concurrent.ConcurrentHashMap;
//import java.util.concurrent.CopyOnWriteArraySet;
//
//import javax.websocket.OnClose;
//import javax.websocket.OnError;
//import javax.websocket.OnMessage;
//import javax.websocket.OnOpen;
//import javax.websocket.Session;
//import javax.websocket.server.ServerEndpoint;
//
//@ServerEndpoint("/websocket")
//public class WebSocket {
//    private Session session;
//    //concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象
//    private static CopyOnWriteArraySet<Session> webSoketSet=new CopyOnWriteArraySet<Session>();
////线程安全的map,实现服务端与单一客户端通信，其中Key为用户标识
//
//    //private static ConcurrentHashMap<String,Session> webSoketMap=new ConcurrentHashMap<String, Session>();
//
//    @OnOpen
//    public void onOpen(Session session){
//        this.session = session;
//        webSoketSet.add(session);
//        //webSoketMap.put("a001", session);//key可以是用户标记
//        System.out.println("有新连接加入！");
//
//    }
//    @OnClose
//    public void onClose(){
//        System.out.println("有一连接关闭！" );
//    }
//
//    @OnMessage
//    public void onMessage(String message, Session session) {
//        System.out.println("来自客户端的消息:" + message);
//        //客户端消息
//	     /* try {
//           //发送信息回客户端
//			session.getBasicRemote().sendText(message);
//		} catch (IOException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}*/
//
//    }
//
//    public static void sentMsg(String msg){
//        //Session session =webSoketMap.get("a001");
//        for (Session session:webSoketSet){
//            try {
//                //发送信息回客户端
//                session.getBasicRemote().sendText(msg);
//            } catch (IOException e) {
//                // TODO Auto-generated catch block
//                e.printStackTrace();
//            }
//        }
//    }
//    @OnError
//    public void onError(Session session, Throwable error){
//        System.out.println("发生错误");
//        error.printStackTrace();
//    }
//}